import reactor.core.publisher.Flux;

public class FluxDemo {

    public static void main(String[] args) {

        // Flux用于创建一个多元素的流
        Flux<Integer> just = Flux.just(1, 2, 3, 4, 5);

        // 流不被消费（订阅）就不会被使用
        just.subscribe(System.out::println);
    }
}
